Instance 0

Class350.runConcurrently(final Callable<Void>... tasks)#0{
    for (final Callable<Void> task : tasks) {
      futures.add(service.submit(task));
    }
    for (final Future<?> future : futures) {
      future.get();
    }
}


Instance 1

Class330.runTest(Class<?> clazz,int invocationCount,int threadCount,Boolean expected)#0{
        final ExecutorService executor = Executors.newFixedThreadPool(threadCount);
        final List<Future<Boolean>> futures = new ArrayList<Future<Boolean>>(threadCount);
        for (int i = threadCount; i > 0; i--) {
            futures.add(executor.submit(new Worker(clazz, invocationCount)));
        }
        for (final Future<Boolean> future : futures) {
            Assert.assertEquals(expected, future.get());
        }
}


Instance 2

Class310.runTest(final Class<?> clazz,final Method method,final int invocationCount,final int threadCount,final Class<?>[] expected){
        final ExecutorService executor = Executors.newFixedThreadPool(threadCount);
        final List<Future<Class<?>[]>> futures = new ArrayList<Future<Class<?>[]>>(threadCount);
        for (int i = threadCount; i > 0; i--) {
            futures.add(executor.submit(new Worker(clazz, method, invocationCount)));
        }
        for (final Future<Class<?>[]> future : futures) {
            Assert.assertArrayEquals(future.get(), expected);
        }
}


Instance 3

Class160.executeTasks(Runnable command,ExecutorService pool)#1{
            futures.add(pool.submit(command));
        for (Future<?> f : futures) {
            f.get();
        }
}


Instance 4

Class170.main(String[] args)#0{
        for(int i = 0; i < 3; i++){
            executorService.submit(new Task(foo, i));
        }
}